package handler

import (
	comHandler "funlog-gserver/handler/nq"

	"github.com/nsqio/go-nsq"
)

type LogNqHandler struct{}

//HandleMessage 处理日志上报消息
func (m *LogNqHandler) HandleMessage(msg *nsq.Message) (err error) {
	// addr := msg.NSQDAddress
	// message := string(msg.Body)
	// fmt.Println(addr, message)
	return comHandler.DoMessage(msg)
}
